
package com.xing.disruptor.logger;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;

public class ArrayBlockingQueueFactory<E> implements BlockingQueueFactory<E> {

    public BlockingQueue<E> create(final int capacity) {
        return new ArrayBlockingQueue<E>(capacity);
    }

    public static <E> ArrayBlockingQueueFactory<E> createFactory() {
        return new ArrayBlockingQueueFactory<E>();
    }
}
